//package com.sdgs.paas.sdk.core.mq;
//
//import java.io.UnsupportedEncodingException;
//import java.util.List;
//
//import com.ctg.mq.api.exception.MQException;
//import com.ctg.mq.api.exception.MQProducerException;
//
///**
// * ctgmq操作接口
// *
// * @author wjj
// *
// */
//public interface ICtgMqManager {
//
//	/**
//	 * 启动消费者实例
//	 * 
//	 * @return 是否启动成功
//	 * @throws MQException
//	 * @throws IllegalAccessException
//	 * @throws InstantiationException
//	 * @throws ClassNotFoundException
//	 */
//	boolean startConsumer(String namesrvAddr, List<ConsumerGroup> consumerGroup, String authID, String authPWD,
//			boolean consumeOrderly, int batchSize, int consumerClientCallbackExecutorThreads,
//			int consumerClientWorkerThreads, int consumerAbMsgProcNetCallbackExecutorThreads,
//			int consumerAbMsgProcNetWorkerThreads)
//			throws MQException, ClassNotFoundException, InstantiationException, IllegalAccessException;
//
//	/**
//	 * 关闭消费者实例
//	 * 
//	 * @return 是否关闭成功
//	 * @throws MQException
//	 */
//	boolean stopConsumer() throws MQException;
//
//	/**
//	 * 启动生产者实例
//	 * 
//	 * @param namesrvAddr
//	 *            队列服务地址
//	 * @param producerGroup
//	 *            生产者组
//	 * @param authID
//	 *            用户名
//	 * @param authPWD
//	 *            密码
//	 * @param maxMessageSize
//	 *            消息最大字节
//	 * @param sendMsgTimeout
//	 *            超时
//	 * @param compressMsgBodyOverHowmuch
//	 *            消息压缩比
//	 * @return 是否启动成功
//	 * @throws MQException
//	 */
//	boolean startProducer(String namesrvAddr, List<ProducerGroup> producerGroup, String authID, String authPWD,
//			int maxMessageSize, int sendMsgTimeout, int compressMsgBodyOverHowmuch) throws MQException;
//
//	/**
//	 * 关闭生产者实例
//	 * 
//	 * @return 是否关闭成功
//	 * @throws MQException
//	 */
//	boolean stopProducer() throws MQException;
//
//	/**
//	 * 
//	 * 
//	 * @param prod_id
//	 * @return
//	 * @throws MQProducerException
//	 */
//	/**
//	 * 写入消息
//	 * 
//	 * @param topic
//	 *            主题
//	 * @param key
//	 *            键值
//	 * @param tag
//	 *            标记
//	 * @param body
//	 *            消息内容
//	 * @return 是否写入成功
//	 * @throws MQProducerException
//	 */
//	boolean createMsg(String topic, String key, String tag, byte[] body) throws MQProducerException;
//
//	/**
//	 * 启动pull模式的consumer
//	 * 
//	 * @param namesrvAddr
//	 *            队列服务地址
//	 * @param authID
//	 *            用户名
//	 * @param authPWD
//	 *            密码
//	 * @throws MQException
//	 */
//	void startPullConsumer(String namesrvAddr, String authID, String authPWD) throws MQException;
//
//	/**
//	 * 拉取消息
//	 * 
//	 * @param topic
//	 *            主题
//	 * @return 消息内容
//	 * @throws MQException
//	 * @throws InterruptedException
//	 * @throws UnsupportedEncodingException
//	 */
//	List<String> pullMsg(String topic) throws MQException, InterruptedException, UnsupportedEncodingException;
//
//	/**
//	 * 启动消费
//	 */
//	void consumeStart();
//
//}
